package wsz;

import org.apache.kafka.clients.consumer.internals.PartitionAssignor;
import org.apache.kafka.common.Cluster;

import java.util.Map;
import java.util.Set;

/**
 * 自定义分区分配策略
 * @author wsz
 * @date 2022/3/16 19:44
 **/
public class MyAssignor implements PartitionAssignor {
    @Override
    public Subscription subscription(Set<String> set) {
        return null;
    }

    @Override
    public Map<String, Assignment> assign(Cluster cluster, Map<String, Subscription> map) {
        return null;
    }

    @Override
    public void onAssignment(Assignment assignment) {

    }

    @Override
    public String name() {
        return null;
    }
}
